from mrjob.job import MRJob
from mrjob.protocol import TextProtocol



class DataRD(MRJob):

    OUTPUT_PROTOCOL = TextProtocol

    def mapper(self, _, line):
        lineinfo = line.strip()
        yield lineinfo, 1

    def combiner(self, lineinfo, counts):
        yield lineinfo, sum(counts)

    def reducer(self, lineinfo, counts):
        yield lineinfo, None


if __name__ == '__main__':
    DataRD.run()

